//package com.sskj.kafka;
//
//import org.springframework.kafka.support.SendResult;
//import org.springframework.util.concurrent.ListenableFutureCallback;
//
///**
// * @author Admin
// */
//public interface KafkaCallback<K, V> extends ListenableFutureCallback<SendResult<K, V>> {
//    @Override
//    default void onSuccess(SendResult<K, V> result) {
//        //回调处理
//    }
//
//    @Override
//    default void onFailure(Throwable ex) {
//        //处理
//    }
//}
